Apache Flink的吞吐量和延迟
我为ApacheFlink写了一个非常简单的Java程序，现在我对测量统计信息感兴趣，例如吞吐量（每秒处理的元组数）和等待时间（程序需要处理每个输入元组的时间）。 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.readTextFile("/home/LizardKing/Documents/Power/Prova.csv") .map(new MyMapper(...
2024-01-10Apache Tiles替代品
我正在编写一个Spring MVC应用程序，正在寻找一种在视图中进行布局的方法。我看到的唯一选择是ApacheTiles，我以前使用过它，并且知道维护其配置是多么痛苦。有什么好的选择吗？我看着SiteMesh和SpringSurf似乎都处于hibernate状态。回答：大约一个月前，我面临着同样的困境。我是一个使用apache tile的经...
2024-01-10Apache Camel条件路由
我有一项服务有两项操作。RegisterUserUpdateUser我有骆驼大溃败：<camel:route id="myRoute"> <camel:from uri="cxf:bean:myListenerEndpoint?dataFormat=POJO&synchronous=true" /> <camel:bean ref="processor" method="processMessage"/> <camel:to uri="xslt:file:r...
2024-01-10更好的替代Apache Tiles
我正在寻找一个比Apache Tiles更易于使用的框架（到目前为止，我已经使用了几次）。使用Tiles时，似乎有100个动作时，我需要创建100个jsp文件并在中创建100个定义tiles.xml。有没有更好的框架来管理我的模板？我想创建例如2个模板：a）菜单和内容栏b）菜单，内容栏，右侧横幅在两个模板中，菜单都是...
2024-01-10Apache Spark中的矩阵乘法
我正在尝试使用Apache Spark和Java执行矩阵乘法。我有两个主要问题：如何创建可以表示Apache Spark中矩阵的RDD？ 如何将两个这样的RDD相乘？回答：所有这些都取决于输入数据和维度，但总的来说，您需要的不是RDD的分布式数据结构之一org.apache.spark.mllib.linalg.distributed。目前，它提供了四种不同的实现Di...
2024-01-10Apache Spark中的分层数据处理
我在Spark（v2.1.1）中有一个包含分层数据的3列（如下所示）的数据集。Apache Spark中的分层数据处理我的目标的目标是增量编号分配给基础上，父子层次的每一行。从图形上可以说，分层数据是一个树的集合。根据下表，我已经有基于'Global_ID'分组的行。现在我想以 的增量顺序生成'Value'列，但是基于 ...
2024-01-10Apache Flink：如何计算DataStream中的事件总数
我有两个原始流，我正在加入这些流，然后我要计算已加入的事件总数是多少，尚未加入的事件有多少。我通过使用joinedEventDataStream如下所示的地图来做到这一点joinedEventDataStream.map(new RichMapFunction<JoinedEvent, Object>() { @Override public Object map(JoinedEvent joinedEvent) throws Exception { ...
2024-01-10Apache Camel路由和Spring引导：应用程序启动
我有一个Spring Boot（1.5.1）应用程序。Apache Camel路由和Spring引导：应用程序启动作为应用程序启动的一部分，它需要调用外部服务。这很好 - 我实现了一个实现ApplicationListener的类，并且外部服务被正确调用。我的问题是，外部服务立即将我的应用程序调回回调URL。对我的应用程序的调用失败，出现404 N...
2024-01-10Apache精简“ Authorization”标头
我的Apache 2.2.15服务器有一个小问题。我正在使用mod_wsgi在其上运行Django应用。我激活了WSGIPassAuthorization On，从而使基本身份验证正常运行。但是我最近实现了OAuth2.0来保护我的API（隐式授予），并且我认为Apache不会通过它，因为它的形式为“授权：承载令牌”。我猜是“承载者”的问题，尽管我不知道...
2024-01-10在Apache Spark中读取多行JSON
我试图将JSON文件用作小型数据库。在DataFrame上创建模板表后，我使用SQL查询了该表并得到了异常。这是我的代码：val df = sqlCtx.read.json("/path/to/user.json")df.registerTempTable("user_tt")val info = sqlCtx.sql("SELECT name FROM user_tt")info.show()df.printSchema() 结果：root |-- _corrupt_record: string (nul...
2024-01-10Apache Spark计数记录每个组的空值
当我尝试计算每个组的记录数时，我发现该组具有空值但没有记录，但这是不正确的。Apache Spark计数记录每个组的空值输入数据帧：+--------+ | Name| +--------+ | Andrei| | Andrei| | null| | null| |Grigorii| +--------+ 代码：Dataset<Row> df = inputDf.groupBy("Name") .agg(functions.count("Name").as("Name_count")); 实际数...
2024-01-10ListenHttp Apache NIfi通用基路径
我想在listenHTTP处理器中使用更通用的基本路径是他们任何方式来指定此webservice接受所有呼入到9090端口或指定一个更通用的基路径，在这种情况下，这是可能的我怎么能在routeonAttribute上使用这个basepath？ListenHttp Apache NIfi通用基路径回答：ListenHTTP不会将基本路径写为属性，因此稍后您将无法使用RouteOn...
2024-01-10如何从Apache Tiles模板引用属性列表
我试图在基本模板中定义一个属性列表，其中包括所有css链接，并且子定义将根据需要附加其他css链接。我在磁贴定义配置文件中定义了该列表，并尝试在template.jsp文件中使用该列表，但是出现以下错误：org.apache.tiles.template.NoSuchAttributeException：导入属性时出错。属性“链接”为空 <?xml version="1.0" ...
2024-01-10Apache POI autoSizeColumn调整大小不正确
我在Java中使用Apache POI创建一个Excel文件。我填写了数据，然后尝试自动调整每列的大小，但是大小总是错误的（我 认为是一致的）。前两行始终（？）完全折叠。当我在excel中自动调整列的大小时，它可以完美运行。（我相信）没有空白单元被写入，并且调整大小是我要做的 件事。 这是一个精简的...
2024-01-10Apache Poi在图像中放置超链接
这是我用于在Excel中将图像作为图标插入的方法：public void insertIcons(String URL, Sheet sheet, int colBegin, int colEnd, int rowBegin, int rowEnd) { try { InputStream iconInput = new FileInputStream(URL); byte[] byteTransf = IOUtils.toByteArray(iconInput); ...
2024-01-10如何通过Apache Camel调用RESTful服务？
我目前正在使用HTTP方法来调用一些URL，这将导致JIRA问题。现在，我想使用Apache Camel，该如何使用？我需要通过骆驼调用以下链接：http://localhost:8080/rest/api/2/project/" + key + /components由于我是Camel的新手，因此也请提出一些解决方案和示例。谢谢回答：您可以轻松使用CXFRS组件；如果出于某种原因需要...
2024-01-10如何在Apache和mod_wsgi中使用Flask路由？
我已经安装了Apache服务器，并且正在通过mod_wsgi处理Flask响应。我已经通过别名注册了WSGI脚本：[httpd.conf]WSGIScriptAlias /service "/mnt/www/wsgi-scripts/service.wsgi"我在上面的路径中添加了相应的WSGI文件：[/mnt/www/wsgi-scripts/service.wsgi]import syssys.path.insert(0, "/mnt/www/wsgi-scripts")from service imp...
2024-01-10将属性写入Apache NiFi中的文件
嗨， 我正在使用GetSNMP处理器来连接无线电。根据NiFi文档，这些信息被写入流文件属性而不是流文件内容。所以，我使用了AttributesToJSON处理器。之后，我使用PutFile处理器将这些属性写入文件。生成文件，但没有写入属性。每个文件中只写入“{}”。使用LogAttribute处理器，我可以看到日志文件中的所有...
2024-01-10Java，如何获取Apache Kafka中某个主题的消息数
我正在使用apache kafka进行消息传递。我已经用Java实现了生产者和消费者。我们如何获取主题中的消息数量？回答：从消费者的角度来看，想到此的唯一方法是实际消费消息并计数。Kafka代理公开了自启动以来收到的消息数量的JMX计数器，但是您不知道已经清除了其中的多少。在最常见的情况下，最好...
2024-01-10Apache Kafka：生产者-Consume API没有在GCP上运行
我一直试图在Kafka集群上运行我的生产者和消费者api，但它不工作。Apache Kafka：生产者-Consume API没有在GCP上运行1）动物园管理员是在一个GCP VM实例运行2）卡夫卡正在另一个GCP VM实例运行步骤如下：步骤1）使用运行动物园管理员以下命令：bin/zookeeper-server-start.sh config/zookeeper.properties 个Zookeeper.propert...
2024-01-10在Hadoop中使用Apache Airflow配置MySql时遇到的问题
我试图在具有以下配置/版本的三个节点的dev Hadoop集群上安装和配置apache airflow：Operating System: Red Hat Enterprise Linux Server 7.7python 3.7.3anaconda 2spark 2.45a)sudo yum install gcc gcc-c++ -yb)sudo yum install libffi-devel mariadb-devel cyrus-sasl-devel -yc)pip install 'apache...
2024-01-10使用Apache FTPClient使FTP服务器返回时间戳列出的文件
我已将以下代码编写为连接到远程FTP服务器（在CentOS 6中为vsftp）。（为简便起见，此处未显示异常处理）FTPClient ftpClient = new FTPClient();ftpClient.setConnectTimeout(20000);ftpClient.connect(serverip);ftpClient.enterLocalPassiveMode();ftpClient.login(username, password);if (!FTPReply.isPositiveComp...
2024-01-10Flink键控流键为空
我试图在Flink中的KeyedStream上执行映射操作：stream.map(new JsonToMessageObjectMapper()) .keyBy("keyfield") .map(new MessageProcessorStateful())JsonToObjectMapper运算符的输出是 类的POJO，它具有String字段“ ”。然后，将流键入此字段。MessageProcessorStateful是一个Ri...
2024-01-10怎样一个角色串联的列在Java的Apache的火花值
我想获得一个特定的列的值表示costs 作为怎样一个角色串联的列在Java的Apache的火花值spark.select(col("col1"), col("col2"), col("costs")) .groupBy("col1") .agg(sum(col("costs"))); 输出应该具有的附加列成本数据与$符号。回答：您需要使用和concat组合litspark.select(col("col1"), col("col2"), col("costs")) .groupBy(...
2024-01-10春云流Kafka粘结剂：“尝试从状态IN_TRANSACTION到状态IN_TRANSACTION的无效转换”
我正在尝试使用Spring云流+ Kafka绑定对Apache Kafka进行“恰好一个交付”概念的一些PoC。春云流Kafka粘结剂：“尝试从状态IN_TRANSACTION到状态IN_TRANSACTION的无效转换”我安装了Apache Kafka“kafka_2.11-1.0.0”，并在生产者中定义了“transactionIdPrefix”，我知道这是我在Spring Kafka中启用事务所需要做的唯一事情，但...
2024-01-10如何从Java中的Apache POI库调用宏？
我有 ：名为“ process”的宏，它为我的工作表完成所有处理工作。我希望使用Apache POI的Java代码调用此宏，以便它可以为我处理工作表。如何在Java的Apache POI中调用宏？我import org.apache.poi.ss.usermodel在Apache POI中使用。请提供示例代码。（我是Apache POI和Java的新手。）回答：我认为这是不...
2024-01-10使用Apache POI的Java程序让我感到奇怪例外
我有一些严重的困难让我的项目离开地面。我有以下代码：使用Apache POI的Java程序让我感到奇怪例外FileInputStream file = new FileInputStream(new File("src/retestchecker/test_sheet.xlsx")); //Get the workbook instance for XLS file XSSFWorkbook workbook = new XSSFWorkbook(file); //Get first sheet from ...
2024-01-10
